0df3bc9dec4bea1f330305619b42d3ba7994fd7f,eventstore/src/test/java/no/ks/eventstore2/eventstore/EventStoreProtoTest.java,EventStoreProtoTest,testActorRestarting,#,118

Before Change


        mongodbJournal.saveEvent(new AggEvent("agg"));

        TestActorRef<Actor> eventstore = TestActorRef.create(_system, EventStore.mkProps(mongodbJournal));
        eventstore.tell(new Subscription("agg",null),super.testActor());
        expectMsgClass(AggEvent.class);
        expectMsgClass(CompleteSubscriptionRegistered.class);
        eventstore.tell(new RemoveSubscription("agg"),super.testActor());

After Change


        mongodbJournal.saveEvent(ProtobufHelper.newEventWrapper("agg", "1", -1, Order.SearchRequest.newBuilder().build()));

        TestActorRef<Actor> eventstore = TestActorRef.create(_system, EventStore.mkProps(mongodbJournal));
        eventstore.tell(Messages.Subscription.newBuilder().setAggregateType("agg").build(),super.testActor());
        expectMsgClass(Messages.EventWrapper.class);
        expectMsgClass(Messages.CompleteSubscriptionRegistered.class);
        eventstore.tell(Messages.RemoveSubscription.newBuilder().setAggregateType("agg").build(),super.testActor());
        expectMsgClass(Messages.SubscriptionRemoved.class);

        eventstore.tell(ProtobufHelper.newEventWrapper("agg", "1", -1, Order.SearchRequest.newBuilder().build()),super.testActor());